package com.ones.sdp.kit.nanomq.model;

import com.ones.sdp.kit.nanomq.constant.OnesNanoMqConsts;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;

import java.io.Serializable;

/**
 * NanoMq发布消息请求Dto
 * @author Clark
 * @version 2024-11-21
 */
@Getter
@Setter
@ToString
public class OnesNanoMqPublishReq implements Serializable {
    /**
     * 客户端Id
     */
    private String clientId;
    /**
     * 主题
     */
    private String topic = "test/connected";
    /**
     * qos
     */
    private int qos = OnesNanoMqConsts.QoSConsts.QOS0;
    /**
     * 消息体
     */
    private String payload = "test succeed";
    /**
     * 是否在服务器上保留消息
     */
    private boolean retain = Boolean.FALSE;
}
